package com.yuanhua.sim.client.socket.handler;

import com.yuanhua.core.base.entity.MsgReqBean;
import com.yuanhua.core.base.entity.MsgResBean;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * * @description TODO
 * * @author songguoxiang@yunquna.com
 * * @date 2024/03/29 15:34
 */
public class MsgReqHandler extends SimpleChannelInboundHandler<MsgReqBean> {
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, MsgReqBean msgReqBean) throws Exception {
        //收到消息
        System.out.println(msgReqBean.getFromuserid() + "说：" + msgReqBean.getMsg());
    }
}
